/*
  @Time : 2019/12/2
  @Author : 6362
*/
package service

func ReceiveMq() {
	/*conn, err1 := amqp.Dial("amqp://guest:guest@122.51.93.207:5672/")
	defer conn.Close()
	log.Println("err1: ", err1)

	ch, _ := conn.Channel()
	defer ch.Close()

	q, err1 := ch.QueueDeclare(
		"hello", // name
		false,   // durable
		false,   // delete when unused
		false,   // exclusive
		false,   // no-wait
		nil,     // arguments
	)
	log.Println("err1:{}", err1)

	msgs, err2 := ch.Consume(
		q.Name, // queue
		"",     // consumer
		true,   // auto-ack
		false,  // exclusive
		false,  // no-local
		false,  // no-wait
		nil,    // args
	)
	log.Println("msgs:{}", msgs)
	log.Println("err2:{}", err2)*/
}
